ee0f0c418dfcc8e65e1ae6783385bd6f399b5346,community/kernel/src/test/java/org/neo4j/unsafe/impl/batchimport/store/io/WriteQueueTest.java,WriteQueueTest,shouldDrainAllOfferedAtOnce,#,64
Before Change
// GIVEN
ExecutorService executor = mock( ExecutorService.class );
JobMonitor jobMonitor = new JobMonitor();
WriteQueue queue = new WriteQueue( executor, jobMonitor );
assertFalse( jobMonitor.hasActiveJobs() );
// WHEN/THEN
WriteJob job1 = mock( WriteJob.class );
WriteJob job2 = mock( WriteJob.class );
queue.offer( job1 );
queue.offer( job2 );
assertArrayEquals( new WriteJob[] {job1, job2}, queue.drain() );
verify( executor, times( 1 ) ).submit( any( Callable.class ) );
reset( executor );
After Change
assertFalse( jobMonitor.hasActiveJobs() );
// WHEN
queue.offer( JOB1 );
queue.offer( JOB2 );
// THEN